package com.lsh.payment.worker.kafka.consumer;

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.kafka.annotation.KafkaListener;

/**
 * Project Name: lsh-oms
 * Created by peter on 17/4/11.
 * 北京链商电子商务有限公司
 * Package
 * desc:
 */
//@Component
public class KafkaReceiver  {

    private static Logger logger = LoggerFactory.getLogger(KafkaReceiver.class);

    //@KafkaListener(topics = {"${topic_name}"})
    public void processMessage(ConsumerRecord<String, String> record) {

        String content = record.value();
        logger.info("************** kafka message is " + content);
    }

}
